google.golang.org/grpc.ClientConn.dopts (field)
82 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L90: DialCreds: cc.dopts.copts.TransportCredentials,
balancer_wrapper.go#L91: CredsBundle: cc.dopts.copts.CredsBundle,
balancer_wrapper.go#L92: Dialer: cc.dopts.copts.Dialer,
balancer_wrapper.go#L94: CustomUserAgent: cc.dopts.copts.UserAgent,
balancer_wrapper.go#L450: if acbw.ccb.cc.dopts.disableHealthCheck {
call.go#L32: opts = combine(cc.dopts.callOptions, opts)
call.go#L34: if cc.dopts.unaryInt != nil {
call.go#L35: return cc.dopts.unaryInt(ctx, method, args, reply, cc, invoke, opts...)
clientconn.go#L149: dopts: defaultDialOptions(),
clientconn.go#L167: opt.apply(&cc.dopts)
clientconn.go#L172: opt.apply(&cc.dopts)
clientconn.go#L181: opt.DialOptionForTarget(cc.parsedTarget.URL).apply(&cc.dopts)
clientconn.go#L191: if cc.dopts.defaultServiceConfigRawJSON != nil {
clientconn.go#L192: scpr := parseServiceConfig(*cc.dopts.defaultServiceConfigRawJSON, cc.dopts.maxCallAttempts)
clientconn.go#L196: cc.dopts.defaultServiceConfig, _ = scpr.Config.(*ServiceConfig)
clientconn.go#L198: cc.keepaliveParams = cc.dopts.copts.KeepaliveParams
clientconn.go#L213: cc.metricsRecorderList = stats.NewMetricsRecorderList(cc.dopts.copts.StatsHandlers)
clientconn.go#L216: cc.idlenessMgr = idle.NewManager((*idler)(cc), cc.dopts.idleTimeout)
clientconn.go#L268: if !cc.dopts.block {
clientconn.go#L272: if cc.dopts.timeout > 0 {
clientconn.go#L274: ctx, cancel = context.WithTimeout(ctx, cc.dopts.timeout)
clientconn.go#L283: case err == nil || !cc.dopts.returnLastError:
clientconn.go#L300: } else if cc.dopts.copts.FailOnNonTempDialError && s == connectivity.TransientFailure {
clientconn.go#L312: if err = cc.connectionError(); err != nil && cc.dopts.returnLastError {
clientconn.go#L327: if cc.dopts.channelzParent != nil {
clientconn.go#L426: if cc.dopts.copts.TransportCredentials == nil && cc.dopts.copts.CredsBundle == nil {
clientconn.go#L429: if cc.dopts.copts.TransportCredentials != nil && cc.dopts.copts.CredsBundle != nil {
clientconn.go#L432: if cc.dopts.copts.CredsBundle != nil && cc.dopts.copts.CredsBundle.TransportCredentials() == nil {
clientconn.go#L435: transportCreds := cc.dopts.copts.TransportCredentials
clientconn.go#L437: transportCreds = cc.dopts.copts.CredsBundle.TransportCredentials()
clientconn.go#L440: for _, cd := range cc.dopts.copts.PerRPCCredentials {
clientconn.go#L457: parentChannel, _ := cc.dopts.channelzParent.(*channelz.Channel)
clientconn.go#L464: interceptors := cc.dopts.chainUnaryInts
clientconn.go#L467: if cc.dopts.unaryInt != nil {
clientconn.go#L468: interceptors = append([]UnaryClientInterceptor{cc.dopts.unaryInt}, interceptors...)
clientconn.go#L480: cc.dopts.unaryInt = chainedInt
clientconn.go#L495: interceptors := cc.dopts.chainStreamInts
clientconn.go#L498: if cc.dopts.streamInt != nil {
clientconn.go#L499: interceptors = append([]StreamClientInterceptor{cc.dopts.streamInt}, interceptors...)
clientconn.go#L511: cc.dopts.streamInt = chainedInt
clientconn.go#L620: dopts dialOptions // Default and user specified dial options.
clientconn.go#L745: if cc.dopts.defaultServiceConfig != nil {
clientconn.go#L746: cc.applyServiceConfigAndBalancer(cc.dopts.defaultServiceConfig, &defaultConfigSelector{cc.dopts.defaultServiceConfig})
clientconn.go#L776: if cc.dopts.disableServiceConfig {
clientconn.go#L857: dopts: cc.dopts,
clientconn.go#L1032: if cc.dopts.authority != "" {
clientconn.go#L1033: return cc.dopts.authority
clientconn.go#L1464: if ac.cc.dopts.disableHealthCheck {
clientconn.go#L1652: for _, rb := range cc.dopts.resolvers {
clientconn.go#L1698: defScheme := cc.dopts.defaultScheme
clientconn.go#L1799: dopts := cc.dopts
resolver_wrapper.go#L59: ignoreServiceConfig: cc.dopts.disableServiceConfig,
resolver_wrapper.go#L75: DisableServiceConfig: ccr.cc.dopts.disableServiceConfig,
resolver_wrapper.go#L76: DialCreds: ccr.cc.dopts.copts.TransportCredentials,
resolver_wrapper.go#L77: CredsBundle: ccr.cc.dopts.copts.CredsBundle,
resolver_wrapper.go#L78: Dialer: ccr.cc.dopts.copts.Dialer,
resolver_wrapper.go#L88: if ccr.cc.dopts.copts.Dialer != nil || !ccr.cc.dopts.useProxy {
resolver_wrapper.go#L91: ccr.resolver, err = delegatingresolver.New(ccr.cc.parsedTarget, ccr, opts, ccr.cc.resolverBuilder, ccr.cc.dopts.enableLocalDNSResolution)
resolver_wrapper.go#L184: return parseServiceConfig(scJSON, ccr.cc.dopts.maxCallAttempts)
stream.go#L167: opts = combine(cc.dopts.callOptions, opts)
stream.go#L169: if cc.dopts.streamInt != nil {
stream.go#L170: return cc.dopts.streamInt(ctx, desc, cc, method, newClientStream, opts...)
stream.go#L317: } else if cc.dopts.compressorV0 != nil {
stream.go#L318: callHdr.SendCompress = cc.dopts.compressorV0.Type()
stream.go#L319: compressorV0 = cc.dopts.compressorV0
stream.go#L341: if !cc.dopts.disableRetry {
stream.go#L347: if cc.dopts.binaryLogger != nil {
stream.go#L348: if ml := cc.dopts.binaryLogger.GetMethodLogger(method); ml != nil {
stream.go#L421: shs := cs.cc.dopts.copts.StatsHandlers
stream.go#L463: decompressorV0: cs.cc.dopts.dc,
stream.go#L532: a.parser = &parser{r: s, bufferPool: a.cs.cc.dopts.copts.BufferPool}
stream.go#L667: if cs.cc.dopts.disableRetry {
stream.go#L919: hdr, data, payload, pf, err := prepareMsg(m, cs.codec, cs.compressorV0, cs.compressorV1, cs.cc.dopts.copts.BufferPool)
stream.go#L1298: } else if ac.cc.dopts.compressorV0 != nil {
stream.go#L1299: callHdr.SendCompress = ac.cc.dopts.compressorV0.Type()
stream.go#L1300: cp = ac.cc.dopts.compressorV0